#if !defined(__APP_MQTT_H__)
#define __APP_MQTT_H__

#define SERVER_URL "tcp://192.168.46.234:12345"
#define PUSH_TOPIC "push_test"
#define PULL_TOPIC "pull_test"

/**
 * @brief 初始化mqtt客户端
 * 
 * @return int 0成功 -1失败
 */
int app_mqtt_init();

/**
 * @brief 通过客户端发送字符串到特定服务器
 * 
 * @param json_str 
 * @return int 
 */
int app_mqtt_send(char *json_str);

/**
 * @brief 注册接收到消息的回调函数
 * 
 * @param callback 回调函数指针
 */
void app_mqtt_registerRecvCallback(int (*callback)(char *));

/**
 * @brief 关闭mqtt客户端
 * 
 */
void app_mqtt_close();

#endif // __APP_MQTT_H__
